package server

import "context"

type JobServer struct {
}

func NewJobServer() *JobServer {
	return &JobServer{}
}

func (s *JobServer) Start(ctx context.Context) error {
	// TODO: 从kafka中读取数据，并处理
	return nil
}

func (s *JobServer) Stop(ctx context.Context) error {
	// TODO: 停止从kafka中读取数据，并处理
	return nil
}
